'''

构造mysql链接

'''
import sys
sys.path.append('../')
import pymysql
from common.config import *


class MysqlClient( object ):

    def __init__(self):

        self._conn = pymysql.Connect( **config )

        self.cursor = self._conn.cursor( pymysql.cursors.DictCursor)


    #随机查询一条状态为0的数据
    def randTask(self,name):

        self.cursor.execute( common["rand_task"].format( name=name ))

        dt = self.cursor.fetchone()

        return dt


    #任务执行状态 1 执行 2 完成 3失败
    def updateTask(self,data ):

        self.cursor.execute( common["update_task"].format( **data ) )

        self._conn.commit()

    def updatePrice(self,data):

        self.cursor.execute(common["update_price"].format(**data))

        self._conn.commit()

        print("\n/*产品价格更新成功:%d*/"%data["id"])
